package com.yang;

import java.util.Collection;

import javax.websocket.Session;

import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONObject;

public class UserService {
	
	/**
	 * 功能：登录
	 * 时间：2016年7月1日下午4:56:08
	 * @author 杨建全
	 * @param msgJson 消息Json
	 * @param session Session
	 * @return
	 */
	public JSONObject doLogin(JSONObject msgJson, Session session) {
		User user = new User();
		user.setUserName(msgJson.getString("userName"));
		user.setSession(session);
		
		SocketServer.loginUsers.put(user.getUserName(), user);
		
		JSONObject result = new JSONObject();
		result.put("event", "LoginSuccess");
		return result;
	}
	/**
	 * 功能：发送群消息
	 * 时间：2016年7月1日下午5:08:29
	 * @author 杨建全
	 * @param msgJson
	 * @param session
	 * @return
	 */
	public JSONObject sendALLMsg(JSONObject msgJson, Session session) {
		String msg = msgJson.getString("msg");
		Collection<User> users = SocketServer.loginUsers.values();
		JSONObject chatJson = new JSONObject();
		chatJson.put("msg", msg);
		chatJson.put("sendUserName", msgJson.getString("userName"));
		for (User user : users) {
			SocketServer.Send(user.getSession(), JSON.toJSONString(chatJson));
		}
		
		JSONObject result = new JSONObject();
		result.put("event", "SendALLMsgSuccess");
		return result;
	}

}
